package com.unhz.generator.utils;

import org.eclipse.paho.client.mqttv3.IMqttDeliveryToken;
import org.eclipse.paho.client.mqttv3.MqttCallback;
import org.eclipse.paho.client.mqttv3.MqttMessage;

/**
 * @Author: 沈佳庆
 * @Description:
 * @Date: Created in 下午 8:17 2018/3/17 0017
 * @Modified By: V1.0.0
 */
public class PushCallback implements MqttCallback {
    public void connectionLost(Throwable cause) {
               // 连接丢失后，一般在这里面进行重连
               System.out.println("连接断开，可以做重连");
            }

            public void deliveryComplete(IMqttDeliveryToken token) {
               System.out.println("deliveryComplete---------" + token.isComplete());
             }

            public void messageArrived(String topic, MqttMessage message) throws Exception {
                 // subscribe后得到的消息会执行到这里面
                 System.out.println("接收消息主题 : " + topic);
                System.out.println("接收消息Qos : " + message.getQos());
                 System.out.println("接收消息内容 : " + new String(message.getPayload()));
           }

}
